}
}.times(1)
);
emitter.emit(new UnitEvent("test", 1));
waitForEmission(emitter);
Assert.assertTrue(httpClient.succeeded());
}.times(1)
);
emitter.emit(event2);
waitForEmission(emitter);
// Nothing should be queued up, since everything has succeeded.